package com.personal.gateway.constant;

/**
 * @author BigHead
 * @date 2021/12/30 16:59
 * @description FlinkCommandConstant
 */
public class FlinkCommandConstant {

    protected final static String START_NO_SAVE_POINT =
            "${FLINK_PATH}/bin/flink\n" +
                    "${START_TYPE}\n" +
                    "${START_CLASS}\n" +
                    "${RUN_ENVIRONMENT}\n" +
                    "${JOB_MANAGER_CONFIG}\n" +
                    "${TASK_MANAGER_CONFIG}\n" +
                    "${FILE_SYSTEM}\n" +
                    "${METRICS}\n" +
                    "${HIGH_AVAILABILITY}\n" +
                    "${JAR_PATH}\n" +
                    "${JAR_PARAMETER}";

    protected final static String STOP_NO_SAVE_POINT =
            "";

    protected final static String START_WITH_SAVE_POINT =
            "${FLINK_PATH}/bin/flink\n" +
                    "${START_TYPE}\n" +
                    "${START_CLASS}\n" +
                    "${SAVE_POINT}\n" +
                    "${RUN_ENVIRONMENT}\n" +
                    "${JOB_MANAGER_CONFIG}\n" +
                    "${TASK_MANAGER_CONFIG}\n" +
                    "${FILE_SYSTEM}\n" +
                    "${METRICS}\n" +
                    "${HIGH_AVAILABILITY}\n" +
                    "${JAR_PATH}\n" +
                    "${JAR_PARAMETER}";

    protected final static String STOP_WITH_SAVE_POINT =
            "${FLINK_PATH}/bin/flink\n" +
                    "stop\n" +
                    "${RUN_ENVIRONMENT}\n" +
                    "${SAVE_POINT}\n" +
                    "${SESSION_ID}";

}
